ceaef105323d031ef92751d2744ad7a0f0be2c08,components/camel-aws/src/main/java/org/apache/camel/component/aws/ddbstream/DdbStreamConsumer.java,DdbStreamConsumer,getShardItertor,#,96
Before Change
GetShardIteratorRequest req = new GetShardIteratorRequest()
.withStreamArn(streamArn)
.withShardId(res1.getStreamDescription().getShards().get(0).getShardId()) // XXX only uses the first shard
.withShardIteratorType(getEndpoint().getIteratorType())
;
GetShardIteratorResult result = getClient().getShardIterator(req);
After Change
.withStreamArn(streamArn)
;
DescribeStreamResult res1 = getClient().describeStream(req1);
shardList.addAll(res1.getStreamDescription().getShards());
LOG.trace("Current shard is: {} (in {})", currentShard, shardList);
if (currentShard == null) {